package org.yonggan.shop.rdd.report

import org.apache.spark.sql.DataFrame
import org.yonggan.shop.constant.ConfigurationManager
import org.yonggan.shop.utils.SparkUtils

/**
  * 商城的PUUV统计数据分析
  */
object ShopRptPvAndUv {

  def main(args: Array[String]): Unit = {

    val spark  = SparkUtils.getSparkSession("商城的PUUV统计数据分析")

    // 文件输出
    val jsonDF: DataFrame = spark.read.json(ConfigurationManager.TASK_INJSON)

    jsonDF.show()



  }

}
